package cn.liangxxhu.rocketmq.core.param;

import lombok.Data;
import java.time.LocalDateTime;

/**
 * 重试失败消息实体（与数据库表映射）
 */
@Data
public class RocketmqFailedMessage {
    private Long id;
    /**
     * 对应MessageWrapper.uuid
     */
    private String messageUuid;
    /**
     * 对应MessageWrapper.topic
     */
    private String topic;
    /**
     * 对应MessageWrapper.tag
     */
    private String tag;
    /**
     * 对应MessageWrapper.keys
     */
    private String keys;
    /**
     * 对应MessageWrapper.eventName
     */
    private String eventName;
    /**
     * 对应MessageWrapper.message（JSON字符串）
     */
    private String messageBody;
    /**
     * 对应MessageWrapper.reconsumeTimes
     */
    private Integer reconsumeTimes;
    /**
     * 失败原因
     */
    private String failReason;
    /**
     * 对应MessageWrapper.timestamp
     */
    private Long sendTimestamp;
    /**
     * 落库时间
     */
    private LocalDateTime createTime;
}